// 异步读取文件
const fs = require('fs');

//批量读写文件(流式操作)

let rs = fs.createReadStream('../1.jpg');
let ws = fs.createWriteStream('2.jpg');

//监听流的打开和关闭


//批量读写文件(流式操作)

let rs = fs.createReadStream('../1.jpg');
let ws = fs.createWriteStream('2.jpg');

//监听流的打开和关闭

// // 打开通道
// ws.once('open', () => {
//     console.log("读取通道已经打开");
// });

// // 关闭通道
// ws.once('close', () => {
//     console.log("读取通道已经关闭");
// });

// // 打开通道
// rs.once('open', () => {
//     console.log("写出通道已经打开");
// });

// // 关闭通道
// rs.once('close', () => {
//     console.log("写出通道已经关闭");
// });

// // 绑定data
// rs.on('data',(data)=>{
//     // console.log(data);
//     ws.write(data);
// })

//创建管道
rs.pipe(ws);//整合上面的代码
